package com.kingsoft.dc.khaos.module.spark.sink

import com.kingsoft.dc.khaos.KhaosContext
import com.kingsoft.dc.khaos.innertype.Schema
import com.kingsoft.dc.khaos.util.Logging
import org.apache.spark.sql.DataFrame
import org.json4s.JsonAST.JObject

trait SinkStrategy extends Logging{

  /** 数据输出 */
  def sink(kc: KhaosContext,
           module_id: String,
           config: JObject,
           schema: Schema,
           dataSet: DataFrame): Any = {}
}
